import os
from celery import Celery,platforms
# 设置 Django 默认设置模块
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'mypro.settings')
# 创建 Celery 应用实例
app=Celery('mypro',broker='redis://localhost:6379/1',backend='redis://localhost:6379/2')
# 从 Django 设置中加载 Celery 配置
app.config_from_object('django.conf:settings')
# 自动发现任务
app.autodiscover_tasks(['base'])  # 重点修改这里，指定包含tasks.py的app名称





# 允许 Celery 以 root 用户运行（生产环境不推荐）
platforms.C_FORCE_ROOT = True
